package com.dtwave.cfstreaming.update;

import com.alibaba.fastjson.JSONObject;
import com.dtwave.cfstreaming.update.function.UpdateFunction;
import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator;
import org.apache.hadoop.hbase.client.Connection;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class StreamDimUpdate {


    public static void updateTableToHbase(SingleOutputStreamOperator<JSONObject> flatMapStream) {
        flatMapStream.filter(new UpdateFunction());
    }
}
